ar socket;
// 是否执行重连 true/不执行 ； false/执行
let lockReconnect = false
// 重连定时器
let wsCreateHandler = null
// 连接成功，执行回调函数
let messageCallback = null
// 连接失败，执行回调函数
let errorCallback = null
// 发送给后台的数据
let sendDatas = {}
import store from '@/store'
export function openSocket_World(data) {

    if (typeof (WebSocket) == "undefined") {
        console.log("您的浏览器不支持WebSocket");
    } else {
        let url = `"ws://${process.env.VUE_APP_SOCKET}/imserver/"` + 'world/' + data;
        if (socket != null) {
            socket.close();
            socket = null;
        }
        socket = new WebSocket(url);
        socket.onopen = function () {
            // console.log("websocket已打开");
            //socket.send("这是来自客户端的消息" + location.href + new Date());
        };
        //获得消息事件
        socket.onmessage = function (msg) {
            let the_data = JSON.parse(msg.data)
            
            store.state.user_chat.world_chat_tableData.push(the_data);
            // if(the_data.b_w_group_id == store.state.user_chat.group_chat_room.group.b_w_group_id){
            //     store.state.user_chat.tableData.push(the_data);
                
            // }
            //发现消息进入开始处理前端触发逻辑
        };
        //关闭事件
        socket.onclose = function () {
            console.log("websocket已关闭");
        };
        //发生了错误事件
        socket.onerror = function () {
            console.log("websocket发生了错误");
        }
    }



}



// 手动关闭websocket （这里手动关闭会执行onclose事件）
export const closeWebsocket_World = () => {
    if (socket) {
    //   writeToScreen('手动关闭websocket')
      socket.close() // 关闭websocket
    //   // wsObj.onclose() // 关闭websocket(如果上面的关闭不生效就加上这一条)
    //   // 关闭重连
    //   lockReconnect = true
    //   wsCreateHandler && clearTimeout(wsCreateHandler)
    //   // 关闭心跳检查
    //   heartCheck.stop()
    }
  }